package com.kancy.delay.queue.redis.key;

/**
 * <p>
 * RedisKeyResolver
 * <p>
 *
 * @author: kancy
 * @date: 2020/3/5 0:01
 **/

public interface RedisKeyResolver {
    /**
     * 获取延时队列的z-set redis key
     * @param topic
     * @return
     */
    String bucketKey(String topic);

    /**
     * 获取消息hashtable redis key
     * @param topic
     * @return
     */
    String hashTableKey(String topic);

    /**
     * 集群环境下，保持key在同一个slot上
     * @param key
     * @return
     */
    String key(String key);
}
